package com.example.cloudstreamrocketmqprovider8801.listener;

import com.alibaba.fastjson.JSON;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Service;

/**
 * @ClassName: HealthListener
 * @Description:
 * @Date 2024/04/09 14:39
 * @Author songshaoqiu
 **/
@RocketMQMessageListener(consumerGroup = "health-check-group", topic = "test-topic")
@Slf4j
@Service
public class HealthListener implements RocketMQListener<String> {
        @Override
        public void onMessage(String message){
            log.info("消费消息:"+message);
            }
}